package com.juanpi.order.configuration.dao;

import com.juanpi.order.configuration.bean.KafkaTopic;
import org.apache.ibatis.annotations.Param;

import java.util.List;

/**
 * @author xueqing
 *         Created on 2017/2/10.
 */
public interface KafkaTopicMapper {
    List<KafkaTopic> queryKafkaTopicByKafkaName(String serviceName);

    void saveKafkaTopics(KafkaTopic kafkaTopic);

    int deleteKafkaTopicsByKafkaName(String kafkaName);

}
